草庐IT

Java ForkJoinPool - 队列中的任务顺序

全部标签

java - 在 Spring Web 服务器中创建线程以运行超时任务

我正在尝试创建一个运行一组任务的线程,如果它没有在特定时间(比如100秒)内完成,则会抛出异常。目前我正在尝试通过将任务封装到runnable对象中并使用ExecutorService和Future类来执行超时执行来实现这一点。然而,当我启动我的Web服务时,我得到了这个异常:java.util.concurrent.ExecutionException:org.springframework.beans.factory.BeanCreationException:Errorcreatingbeanwithname'scopedTarget.localhostInterpolatorH

java - 用于 Java 任务控制的基于命令行的守护进程?备择方案?

我被要求调查OracleJavaMissionControl,以便在特定条件下可以监视服务器端Java应用程序并采取行动(例如发出和记录警报、保存飞行记录)。JavaMissionControl的触发系统,您可以在其中指定条件和操作,满足我们的需求,但它似乎取决于正在运行的GUI应用程序(“OracleJavaMissionControl”),这意味着触发器不是受监视的JMX服务器的责任。是这样吗?有许多服务器通常通过终端访问...有没有办法在终端session中将JavaMissionControl作为守护进程运行,无人值守,同时保留并遵守任何指定的触发规则(例如,从XML文件导入)

java - RabbitMQ 如何将作业拆分为任务并处理结果

我在基于Spring的Web应用程序上有以下用例:我需要应用具有以下特点的竞争消费者EIP:队列中的消息实际上是属于同一作业的拆分任务。因此,我需要正确跟踪作业的所有任务何时完成及其完成状态,以便将场景保存为完成或失败,记录结果并通过例如通知。相应地向用户发送电子邮件因此,根据我上面描述的要求,我的问题是:这可以用RabbitMQ完成吗?如果可以,怎么做? 最佳答案 我创建了一个快速gist展示一个如何做到这一点的非常粗略的例子。在这个例子中,有一个生产者和2个消费者,2个队列,一个由生产者发送(“SEND”),由消费者消费,反之亦

Spark---Master启动及Submit任务提交

一、SparkMaster启动1、Spark资源任务调度对象关系图2、集群启动过程Spark集群启动之后,首先调用$SPARK_HOME/sbin/start-all.sh,start-all.sh脚本中调用了“start-master.sh”脚本和“start-slaves.sh”脚本,在start-master.sh脚本中可以看到启动Master角色的主类:“org.apache.spark.deploy.master.Master”。在对应的start-slaves.sh脚本中又调用了start-slave.sh脚本,在star-slave.sh脚本中可以看到启动Worker角色的主类:

java - 使用定时器安排多个任务

如何使用java.util.Timer安排多项任务.我想使用计时器读取多个文件。我想我必须给每个文件一个不同的TimerTask以便一个文件获得一个TimerTask实例而另一个文件获得另一个实例,但我不知道该怎么做.请帮忙。提前致谢。这是我正在做的:Timertimer=newTimer();//repeatthecheckeverysecondtimer.schedule(fileWatcherTask,newDate(),1000); 最佳答案 作为javadocTimer类表明您的任务应该花费很少的时间。在这种情况下,您可以

java - GWT:如何将事件放入队列(相当于 Swing invokeLater())?

有以下情况:模糊文本框(输入)将文本写入我的状态框(在某些情况下),单击按钮也会将文本写入状态框。现在,当单击按钮时,如果它获得焦点,它将模糊我的文本框,这将导致状态框闪烁,因为首先blurHandler将写入其结果,然后是clickHandler。因为我希望clickHandler的结果出现,所以我的想法是让blurHandler在队列末尾放置一个事件,检查clickHandler之前是否已经写入结果。在Swing中我会尝试SwingUtilities.invokeLater(可运行)。GWT中的等价物据说是Scheduler但是那些延迟或最终命令似乎总是在当前事件之后和下一个事件之

java - 使用 Java Collat​​or 区分大小写的顺序

我正在尝试使用JavaCollator了解区分大小写的顺序应该如何真正起作用.在thisexample以下字符串在法语语言环境中使用所有优势进行排序(出于说明目的,我在数据集中添加了一些额外的字符串):[Äbc,äbc,Àbc,àbc,Abc,abc,ABC]-OriginalData[Äbc,äbc,Àbc,àbc,Abc,abc,ABC]Primary[Abc,abc,ABC,Àbc,àbc,Äbc,äbc]Secondary[abc,Abc,ABC,àbc,Àbc,äbc,Äbc]TertiaryCasekicksinonlywithTertiaryCollationStreng

java - 顺序拆分器上的 estimateSize()

我正在实现一个Spliterator,它通过让trySplit()返回null来明确限制并行化。实现estimateSize()是否会为此拆分器生成的流提供任何性能改进?或者估计大小仅对并行化有用?编辑:为澄清起见,我特别询问的是估计尺寸。换句话说,我的拆分器没有SIZED特性。 最佳答案 查看相关拆分器特征的调用层次结构表明它至少与stream.toArray()性能相关此外,在内部流实现中还有一个等效标志似乎用于排序:所以除了并行流操作之外,大小估计似乎也用于这两个操作。我的搜索并不详尽无遗,因此仅以这些为例。如果没有SIZED

java - Java groupingBy 收集器是否保留列表顺序?

考虑一个列表List其中元素按People.getAge()的升序排序.如果我们使用Collectors.groupingBy(People::getCity)对这个列表进行分组,每个组/城市的结果列表是否仍按年龄排序?实际上,它似乎确实保留了顺序。我正在寻找保证。该方法的Javadoc说:IfpreservationoftheorderinwhichelementsappearintheresultingMapcollectorisnotrequired,usinggroupingByConcurrent(Function)mayofferbetterparallelperforma

java - 如何让 gradle ShadowJar 任务也创建其子项的源代码和 javadoc?

我有一个包含8个子项目的gradle项目和一个配置的shadowjar任务来创建一个“所有”jar。顶层项目设置为对其所有子项目具有依赖性,这告诉shadowjar要包含的内容:project(':'){dependencies{compileproject(':jfxtras-agenda')compileproject(':jfxtras-common')compileproject(':jfxtras-controls')compileproject(':jfxtras-icalendarfx')compileproject(':jfxtras-icalendaragenda')